package com.zr.flink.thread;

public class ThreadDemo implements Runnable{

    private final DataProcessor processor;

    public ThreadDemo(DataProcessor processor) {
        this.processor = processor;
    }

    @Override
    public void run() {
        processor.processor();
    }
}
